"""
@name : 9-多进程-生产者消费者模式
@author : wenyao
@projectname: sanchuanglianxi
"""
from multiprocessing import Process, Queue
import time,os

def consumer(q):
    while True:
        res = q.get()
        print("%s 吃了 %s"%(os.getpid(), res))

def producer(q):
    for i in range(10):
        res = "包子%s"%i
        q.put(res)
        print("%s 生产了 %s"%(os.getpid(),res))

if __name__ == "__main__":
    q = Queue()
    #生产者
    p1 = Process(target = producer, args=(q,))

    #消费者
    p2 = Process(target=consumer, args=(q,))

    p1.start()
    p2.start()

#自产自消
#架构
#消息中间件  实现一个业务的解耦 （kafka、rabbitmq、nsq）
#日志 --》处理  --》 数据库
#日志收集机器5台  --> kafka(5台) -->我们自己处理  --》存入数据库
#                                 --》别的部门也需要
